package com.tenton.service.impl;

import com.tenton.kafka.KafkaProducer;
import com.tenton.service.KafkaService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @Author：TangDong
 * @Date：2022/3/29
 * @Description：
 */
@Service
public class KafkaServiceImpl implements KafkaService {
    
    @Autowired
    private KafkaProducer kafkaProducer;
    @Override
    public void send() {
        kafkaProducer.send("this is a test kafka topic message");
    }
}
